package org.framework.wu.framework.queue.listener.demo;

import org.framework.wu.framework.queue.Message;
import org.framework.wu.framework.queue.listener.AbstractQueueListener;
import org.framework.wu.framework.queue.listener.QueueListener;

public class DemoQueueListener extends AbstractQueueListener implements QueueListener {
    /**
     * 监听数据
     *
     * @param demoMsg 队列消息
     * @throws Exception
     */
    @Override
    public void listener(Message demoMsg) throws Exception {

    }

    /**
     * 获取队列名称
     *
     * @return 队列名称
     */
    @Override
    public String queueName() {
        return "demo_queue";
    }

    /**
     * 获取队列类型
     *
     * @return 队列类型
     */
    @Override
    public String queueType() {
        return "";
    }

    /**
     * 获取队列topic
     *
     * @return 队列topic
     */
    @Override
    public String topic() {
        return "demo_topic";
    }
}
